package com.biz.user.mq;

import lombok.extern.slf4j.*;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.stereotype.*;

/**
 * @Description RabbitMQ消息接收
 *
 * @Author liuxi
 * @Date 2024/6/30
 **/
@Component
@RabbitListener(queues = "myQueues")
@Slf4j
public class TestRabbitMQConsumer {

    @RabbitHandler
    public void process(String s) {
        log.info("接收到了mq:{}", s);
    }

}
